package com.taobao.top.link.endpoint;

import java.util.Map;

public interface MessageHandler {
  public void onMessage(EndpointContext context) throws Exception;

  // just got msg that can not reply
  public void onMessage(Map<String, String> message, Identity messageFrom);
}